package com.zc.redisson.delayedQueue.handler;


import com.zc.redisson.delayedQueue.message.DelayMessage;
import com.zc.redisson.stream.domain.FactoryCommAlarmRule;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.Date;
import java.util.List;

/**
 * @description 任务消息处理器
 */
@Component
public class CommAlarmDelayMessageHandler implements DelayMessageHandler<FactoryCommAlarmRule> {

    private final Logger log = LoggerFactory.getLogger(CommAlarmDelayMessageHandler.class);


    @Override
    public void handle(DelayMessage<FactoryCommAlarmRule> message) {
        FactoryCommAlarmRule alarmRule = message.getBody();
        String deviceUuid = alarmRule.getDeviceUuid();
        log.info("通信中断延迟队列消息处理开始，message：{}", message);
    }
}
